package share.cyclicBarrier;

import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
 * @author 小石潭记
 * @date 2021/4/20 21:50
 * @Description: 可循环利用的屏障
 */
public class CyclicBarrierExample {
    static class PreTaskThread implements Runnable {
        private String task;
        private CyclicBarrier cyclicBarrier;

        public PreTaskThread(String task, CyclicBarrier cyclicBarrier) {
            this.task = task;
            this.cyclicBarrier = cyclicBarrier;
        }

        @Override
        public void run() {
            for (int i = 0; i < 4; i++) {
                Random random = new Random();
                try {
                    Thread.sleep(random.nextInt(1000));
                    System.out.println(String.format("关卡 %d 的任务 %s 完成", i, task));
                    // 线程调用 await() 表示自己已经到达栅栏
                    // BrokenBarrierException 表示栅栏已经被破坏，
                    // 破坏的原因可能是其中一个线程 await() 时被中断或者超时
                    cyclicBarrier.await();
                } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }
        }

        public static void main(String[] args) {
            // parties 是参与线程的个数
            // 第二个构造方法有一个 Runnable 参数，这个参数的意思是最后一个到达线程要做的任务
            CyclicBarrier cyclicBarrier = new CyclicBarrier(3, () ->
                System.out.println("本关卡所有的前置任务完成，开始游戏... ...")
            );
            new Thread(new PreTaskThread("加载地图数据", cyclicBarrier)).start();
            new Thread(new PreTaskThread("加载人物模型", cyclicBarrier)).start();
            new Thread(new PreTaskThread("加载背景音乐", cyclicBarrier)).start();
        }
    }
}
